from __future__ import absolute_import, unicode_literals
import os
from celery import Celery

# 设置环境变量
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'seckill_java_topy.settings')

# 创建 Celery 实例
app = Celery('seckill_java_topy')

# 使用 Django 的 settings 文件配置 Celery
app.config_from_object('django.conf:settings', namespace='CELERY')
# app.conf.update(
#     worker_max_tasks_per_child=1000,  # 每个子进程处理1000任务后重启
#     worker_prefetch_multiplier=1,     # 避免任务堆积
#     task_acks_late=True,              # 防止任务中断导致连接未释放
#     broker_pool_limit=20              # 限制 broker 连接数
# )
# 自动发现任务
app.autodiscover_tasks()



